package db

import (
	"pd/server/com"
)

var (
	localKafkaAddrList  = []string{"localhost:9092"}
	onlineKafkaAddrList = []string{}
)

func GetKafkaAddrList() []string {
	if com.IsLocal() {
		return localKafkaAddrList
	}

	return onlineKafkaAddrList
}

func GetSQSConnInfo() (region, accessKey, secretKey string) {
	if com.IsLocal() {
		region = "cn-northwest-1"
		accessKey = "AKIASXJK2L2PFKCEQVNA"
		secretKey = "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"
	} else {
		region = "cn-northwest-1"
		accessKey = "AKIASXJK2L2PFKCEQVNA"
		secretKey = "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"
	}
	return
}

// func GetTopicName(topic string) string {
// 	if com.IsLocal() {
// 		return topic + "_debug"
// 	}
// 	return topic
// }
